package org.redis.cluster.test.transport.redis;

import org.junit.Assert;
import org.junit.Test;
import org.redis.cluster.redis.processor.RedisErrorReplyProcessor;
import org.redis.cluster.redis.transport.reply.RedisErrorReply;

public class RedisErrorReplyProcessorTester {

	@Test
	public void test() {
		RedisErrorReplyProcessor processor=new RedisErrorReplyProcessor();
		RedisErrorReply reply=new RedisErrorReply("test error");
		byte result[]=processor.process(reply);
		Assert.assertEquals("-test error\r\n", new String(result));
	}
}